package com.yangc.stream.rabbit;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;


import com.yangc.stream.rabbit.entity.LogMessage;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.Message;

import java.util.function.Function;

@SpringBootApplication
public class LogEnricherV3Application {

    public static void main(String[] args) {
        SpringApplication.run(LogEnricherV3Application.class, args);
    }

    @Bean
    Function<LogMessage, String> highlightLogs() {
        return logMsg -> logMsg.message().toUpperCase();
    }
}